/********************************************************/
/*	Copyright (C) 2016 Gong Li Bin			*/
/*	Project:	MapReduce			*/
/*	Author:		gong_libin			*/
/*	Date:		2016_06_01			*/
/*	File:		MrAccept.h			*/
/********************************************************/

#ifndef	_MRACCEPT_H
#define	_MRACCEPT_H 

#include "MrJob.h"
#include "MrUtils.h"

#define	MR_AC_VERSION			(char*)"MrAccept-2.0.0"

#define	MR_AC_PORT			(char*)"SELECT Port FROM %s.%s WHERE HostID=%s"
#define	MR_AC_POLL			(char*)"SELECT HostID,Addr,Port FROM %s.%s where Type=0"
#define	MR_AC_PROC			(char*)"SELECT HostID,Addr,Port FROM %s.%s where Type=2"

void* MrAcceptThreadCore(void* pNULL);
int MrAcceptConfig(char* pszConf, char* pszPort);
void MrAcceptProcExec(CMrUdp& rCSend, UINT* puiProc, UCHAR* puszSend, int iLength);

#endif /* _MRACCEPT_H */
